e002acab5729f85fe225b62aea5492c8928d188b,cdap-app-templates/cdap-etl/cdap-etl-realtime/src/main/java/co/cask/cdap/template/etl/realtime/ETLWorker.java,ETLWorker,initialize,#WorkerContext#,81
Before Change
initializeSource(context, config.getSource());
List<Transformation> transforms = initializeTransforms(context,
config.getTransforms().or(Lists.<ETLStage>newArrayList()));
initializeSink(context, config.getSink());
transformExecutor = new TransformExecutor(transforms, transformMetrics);
After Change
});
initializeSource(context, config.getSource());
List<Transformation> transforms = initializeTransforms(context, config.getTransforms());
initializeSink(context, config.getSink());
transformExecutor = new TransformExecutor(transforms, transformMetrics);